package com.cetc.sdp.kmga.cs.stream;

import com.cetc.sdp.kmga.cs.util.WorkConf;
import com.cetc.sdp.kmga.cs.util.WorkConfImpl;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.streaming.api.java.JavaStreamingContext;

/**
 * 程序入口, 测试用
 * @description:
 * @author： DengQiang
 * @date: 2018/3/8 16:45
 *
 */
public final class Driver {

    public static void main(String[] args) {
        StreamWork sw = new StreamWork(new WorkConfImpl());
//        sw.addStream();
    }

}
